554dc6a0a8aa2e6f510d4a4dd44de92fa13c17e2,src/test/java/com/rabbitmq/client/test/BrokerTestCase.java,BrokerTestCase,newConnectionFactory,#,62

Before Change


        if(nio()) {
            connectionFactory.setNio(true);
            this.nioExecutor = Executors.newFixedThreadPool(5);
            connectionFactory.setNioExecutor(this.nioExecutor);
        } else {
            connectionFactory.setNio(false);
            this.nioExecutor = null;

After Change


        if(nio()) {
            connectionFactory.setNio(true);
            this.nioExecutor = Executors.newFixedThreadPool(5);
            connectionFactory.setNioParams(new NioParams().setNioExecutor(this.nioExecutor));
        } else {
            connectionFactory.setNio(false);
            this.nioExecutor = null;